c319ba16f46cb8d9a3570cfc22a2ba53d0103177,core/src/main/java/com/aliyun/fs/oss/blk/JetOssFileSystemStore.java,JetOssFileSystemStore,initialize,#URI#Configuration#,80

Before Change


        this.conf = conf;
        String endpoint = conf.get("fs.oss.endpoint");
        String accessKeyId = conf.get("fs.oss.accessKeyId");
        String accessKeySecret = conf.get("fs.oss.accessKeySecret");
        String securityToken = conf.get("fs.oss.securityToken");
        if (securityToken == null) {
            this.ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);

After Change


    }

    public void initialize(URI uri, Configuration conf) throws IOException {
        if (uri.getHost() == null) {
            throw new IllegalArgumentException("Invalid hostname in URI " + uri);
        }
        this.conf = conf;
        String userInfo = uri.getUserInfo();
        if (userInfo != null) {
            String[] ossCredentials  = userInfo.split(":");
            if (ossCredentials.length >= 2) {
                accessKeyId = ossCredentials[0];
                accessKeySecret = ossCredentials[1];
            }
            if (ossCredentials.length == 3) {
                securityToken = ossCredentials[2];
            }
        }

        if (accessKeyId == null) {
            accessKeyId = conf.getTrimmed("fs.oss.accessKeyId");
        }
        if (accessKeySecret == null) {
            accessKeySecret = conf.getTrimmed("fs.oss.accessKeySecret");
        }
        if (securityToken == null) {
            securityToken = conf.getTrimmed("fs.oss.securityToken");